package HDFS;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;

/**
 * 文件下载
 */
public class Test_02 {
    public static void main(String[] args) throws IOException, URISyntaxException, InterruptedException {
        //设置本地文件
        Configuration conf = new Configuration();
        //获取文件系统（三个参数：final URI uri, final Configuration conf, String user）
        FileSystem fs =FileSystem.get(new URI("hdfs://bigdata211:9000"),conf,"root");
        // 调用FileSystem的方法
        // （四个参数：是否删除源文件，Hdfs的下载地址，存放本地路径，是否使用本地的文件系统）
        fs.copyToLocalFile(true,
                new Path("hdfs://bigdata211:9000/data/word.txt"),
                new Path("D:\\"),true);
        fs.close();
        System.out.println("下载成功！");
    }
}
